const mysql = require('mysql');
const { MYSQL_CONFIG } = require('../config/db')

// 创建连接对象
const connection = mysql.createConnection(MYSQL_CONFIG)

connection.connect();

// 执行 sql 语句 未封装
// const sql = `select * from blogs`;	//查询
// const sql = `insert into blogs (title, content, author, createdAt) values ('标题5', '内容5', '张三丰', '5534567891230')`;
// connection.query(sql, (error, result) => {
// 	if(error){
// 		console.error('error', error)
// 		return
// 	}
// 	console.log('result', result)
// })


// 执行sql语句 - callback
// function execSQL(sql, callback){
// 	connection.query(sql, callback);
// }

// 执行sql语句 - promise
function execSQL(sql){
	const promise = new Promise((resolve, reject) => {
		connection.query(sql, (error, result) => {
			if (error) {
				reject(error)
				return
			}
			resolve(result)
		})
	})
	return promise;
}

module.exports = {
	execSQL
}